//package demo.job.elastic;
//
//import java.util.List;
//import java.util.stream.Collectors;
//import java.util.stream.IntStream;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
//import com.dangdang.ddframe.job.api.ShardingContext;
//import com.dangdang.ddframe.job.api.dataflow.DataflowJob;
//
///**
// * 魔蝎运营商账单
// *
// * @author hanjy
// */
//public class DataflowJobDemo implements DataflowJob<String> {
//
//    private static final Logger logger = LoggerFactory.getLogger(DataflowJobDemo.class);
//
//    @Override
//    public List<String> fetchData(ShardingContext shardingContext) {
//        logger.info("开始执行任务：{}", shardingContext);
//        return IntStream.range(0, 10).mapToObj(Integer::toString).collect(Collectors.toList());
//    }
//
//    @Override
//    public void processData(ShardingContext shardingContext, List<String> data) {
//        switch (shardingContext.getShardingItem()) {
//        case 0:
//            logger.info("执行任务分片：{}", shardingContext.getShardingItem());
//            break;
//        case 1:
//            logger.info("执行任务分片：{}", shardingContext.getShardingItem());
//            break;
//        case 2:
//            logger.info("执行任务分片：{}", shardingContext.getShardingItem());
//            break;
//        default:
//            logger.error("error ShardingItem:{}", shardingContext.getShardingItem());
//            break;
//        }
//        logger.info("执行任务：{}", data);
//        logger.info("任务执行结束：{}", shardingContext);
//    }
//
//}
